package com.aioething.iot.service;

import cn.hutool.http.HttpResponse;
import cn.hutool.json.JSONObject;
import okhttp3.Response;
import org.tio.utils.lock.MapWithLock;

import java.io.IOException;

public interface IEmqxService {
    HttpResponse publish(String topic, String payload) throws IOException;
    JSONObject actionCall(String topic, String method, String equipmentId, JSONObject params) throws IOException;
    MapWithLock<String, String> getSyncLock();
}
